org.springframework.jms.config

Class DefaultJmsListenerContainerFactory

java.lang.Object

org.springframework.jms.config.AbstractJmsListenerContainerFactory<DefaultMessageListenerContainer>

org.springframework.jms.config.DefaultJmsListenerContainerFactory

All Implemented Interfaces:

JmsListenerContainerFactory<DefaultMessageListenerContainer>

public class DefaultJmsListenerContainerFactory
extends AbstractJmsListenerContainerFactory<DefaultMessageListenerContainer>

A JmsListenerContainerFactory implementation to build a regular DefaultMessageListenerContainer.

This should be the default for most users and a good transition paths for those that are used to build such container definition manually.

Since:

4.1

Author:

Stephane Nicoll

Field Summary

Fields

Modifier and Type	Field and Description
private BackOff	backOff
private java.lang.Integer	cacheLevel
private java.lang.String	cacheLevelName
private java.lang.String	concurrency
private java.lang.Integer	maxMessagesPerTask
private java.lang.Long	receiveTimeout
private java.lang.Long	recoveryInterval
private java.util.concurrent.Executor	taskExecutor
private PlatformTransactionManager	transactionManager

Fields inherited from class org.springframework.jms.config.AbstractJmsListenerContainerFactory

logger

Constructor Summary

Constructors

Constructor and Description
DefaultJmsListenerContainerFactory()

Method Summary

Modifier and Type	Method and Description
protected DefaultMessageListenerContainer	createContainerInstance() Create an empty container instance.
protected void	initializeContainer(DefaultMessageListenerContainer container) Further initialize the specified container.
void	setBackOff(BackOff backOff)
void	setCacheLevel(java.lang.Integer cacheLevel)
void	setCacheLevelName(java.lang.String cacheLevelName)
void	setConcurrency(java.lang.String concurrency)
void	setMaxMessagesPerTask(java.lang.Integer maxMessagesPerTask)
void	setReceiveTimeout(java.lang.Long receiveTimeout)
void	setRecoveryInterval(java.lang.Long recoveryInterval)
void	setTaskExecutor(java.util.concurrent.Executor taskExecutor)
void	setTransactionManager(PlatformTransactionManager transactionManager)

Methods inherited from class org.springframework.jms.config.AbstractJmsListenerContainerFactory

createListenerContainer, setClientId, setConnectionFactory, setDestinationResolver, setErrorHandler, setMessageConverter, setPhase, setPubSubDomain, setSessionAcknowledgeMode, setSessionTransacted, setSubscriptionDurable, setSubscriptionShared

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

taskExecutor

private java.util.concurrent.Executor taskExecutor

transactionManager

private PlatformTransactionManager transactionManager

cacheLevel

private java.lang.Integer cacheLevel

cacheLevelName

private java.lang.String cacheLevelName

concurrency

private java.lang.String concurrency

maxMessagesPerTask

private java.lang.Integer maxMessagesPerTask

receiveTimeout

private java.lang.Long receiveTimeout

recoveryInterval

private java.lang.Long recoveryInterval

backOff

private BackOff backOff

Constructor Detail

DefaultJmsListenerContainerFactory

public DefaultJmsListenerContainerFactory()

Method Detail

setTaskExecutor

public void setTaskExecutor(java.util.concurrent.Executor taskExecutor)

See Also:

DefaultMessageListenerContainer.setTaskExecutor(java.util.concurrent.Executor)

setTransactionManager

public void setTransactionManager(PlatformTransactionManager transactionManager)

See Also:

AbstractPollingMessageListenerContainer.setTransactionManager(org.springframework.transaction.PlatformTransactionManager)

setCacheLevel

public void setCacheLevel(java.lang.Integer cacheLevel)

See Also:

DefaultMessageListenerContainer.setCacheLevel(int)

setCacheLevelName

public void setCacheLevelName(java.lang.String cacheLevelName)

See Also:

DefaultMessageListenerContainer.setCacheLevelName(java.lang.String)

setConcurrency

public void setConcurrency(java.lang.String concurrency)

See Also:

DefaultMessageListenerContainer.setConcurrency(java.lang.String)

setMaxMessagesPerTask

public void setMaxMessagesPerTask(java.lang.Integer maxMessagesPerTask)

See Also:

DefaultMessageListenerContainer.setMaxMessagesPerTask(int)

setReceiveTimeout

public void setReceiveTimeout(java.lang.Long receiveTimeout)

See Also:

AbstractPollingMessageListenerContainer.setReceiveTimeout(long)

setRecoveryInterval

public void setRecoveryInterval(java.lang.Long recoveryInterval)

See Also:

DefaultMessageListenerContainer.setRecoveryInterval(long)

setBackOff

public void setBackOff(BackOff backOff)

See Also:

DefaultMessageListenerContainer.setBackOff(org.springframework.util.backoff.BackOff)

createContainerInstance

protected DefaultMessageListenerContainer createContainerInstance()

Description copied from class: AbstractJmsListenerContainerFactory

Create an empty container instance.

Specified by:

createContainerInstance in class AbstractJmsListenerContainerFactory<DefaultMessageListenerContainer>

initializeContainer

protected void initializeContainer(DefaultMessageListenerContainer container)

Description copied from class: AbstractJmsListenerContainerFactory

Further initialize the specified container.

Subclasses can inherit from this method to apply extra configuration if necessary.

Overrides:

initializeContainer in class AbstractJmsListenerContainerFactory<DefaultMessageListenerContainer>